package common.config.rocketmq;

/**
 * 消息延迟等级<br/>
 * {@link org.apache.rocketmq.remoting.protocol.subscription.CustomizedRetryPolicy}
 *
 * @author 米泽鹏
 * @since 2022-5-11 下午 8:27
 */
public class RocketMqConstants {

	/**
	 * nameserver address
	 */
	public static final String NAMESERVER_ADDRESS = "localhost:9876";

	/**
	 * 生产者分组前缀
	 */
	public static final String PRODUCER_GROUP_PREFIX = "MqProducer-";

	/**
	 * 消费者分组前缀
	 */
	public static final String CONSUMER_GROUP_PREFIX = "MqConsumer-";

}
